0f8d838a7fc93237a0ffbf14f3199cedce6933cd,src/org/jgroups/protocols/pbcast/NAKACK.java,NAKACK,handleXmitReq,#Address#number#number#,510

Before Change


            log.trace("received xmit request for " + dest + " [" + first_seqno + " - " + last_seqno + "]");

        if(first_seqno > last_seqno) {
            if(log.isErrorEnabled())
                log.error("first_seqno (" + first_seqno + ") > last_seqno (" + last_seqno + "): not able to retransmit");
            return;
        }
        list=new LinkedList();
        for(long i=first_seqno; i <= last_seqno; i++) {
            m=(Message)sent_msgs.get(new Long(i)); // no need to synchronized
            if(m == null) {
                if(log.isErrorEnabled())
                    log.error("(requester=" + dest + ", local_addr=" + this.local_addr + ") message with " +
                            "seqno=" + i + " not found in sent_msgs ! sent_msgs=" + printSentMsgs());
                continue;
            }
            len=m.size();

After Change


        }

        if (first_seqno > last_seqno) {
            if (log.isErrorEnabled()) {
                log.error(
                        "first_seqno (" + first_seqno + ") > last_seqno (" + last_seqno + "): not able to retransmit");
            }
            return;
        }
        list = new LinkedList();
        for (long i = first_seqno; i <= last_seqno; i++) {
            m = (Message) sent_msgs.get(new Long(i)); // no need to synchronized
            if (m == null) {
                if (log.isErrorEnabled()) {
                    log.error(
                            "(requester=" + dest + ", local_addr=" + this.local_addr + ") message with " +
                            "seqno=" + i +
                            " not found in sent_msgs ! sent_msgs=" +
                            printSentMsgs());
                }
                continue;
            }